package com.taobao.txc.client.a.a;

import com.taobao.txc.common.LoggerWrap;
import java.util.concurrent.BlockingQueue;

final class b
  implements Runnable
{
  public void run()
  {
    for (;;)
    {
      if ((a.a.size() > 0) || (a.b.size() > 0))
      {
        StringBuilder localStringBuilder = new StringBuilder();
        while (!a.a.isEmpty()) {
          localStringBuilder.append((String)a.a.poll()).append(" ");
        }
        int i = localStringBuilder.length();
        if (i > 0) {
          localStringBuilder.append("begin. \t");
        }
        i = localStringBuilder.length();
        while (!a.b.isEmpty()) {
          localStringBuilder.append(a.b.poll()).append(" ");
        }
        if (localStringBuilder.length() > i) {
          localStringBuilder.append("commit finished.");
        }
        a.e().info(localStringBuilder.toString());
      }
      try
      {
        Thread.sleep(10L);
      }
      catch (InterruptedException localInterruptedException)
      {
        localInterruptedException.printStackTrace();
      }
    }
  }
}


/* Location:           C:\Users\ibm\Downloads\txc-yun-sample (1)\txc-yun-sample\lib\txc-client-2.0.72.jar
 * Qualified Name:     com.taobao.txc.client.a.a.b
 * JD-Core Version:    0.7.0.1
 */